package com.netty.common.constant;

/**
 * @author LiuXiaoYu
 * @date 2021/10/17- 19:52
 */
public class MqConstants {

    public static final String NETTY_MESSAGE_EXCHANGE="nettyMessageExchange";
    public static final String NETTY_MESSAGE_ROUTING_KEY="nettyMessageRoutingKey";
    public static final String NETTY_MESSAGE_QUEUE="nettyMessageQueue";
    public static final String NETTY_MESSAGE_DEAD_EXCHANGE="nettyMessageDeadExchange";
    public static final String NETTY_MESSAGE_DEAD_ROUTING_KEY="nettyMessageDeadRoutingKey";
    public static final String NETTY_MESSAGE_DEAD_QUEUE="nettyMessageDeadQueue";
    /**存在redis中 消息key*/
    public static final String NETTY_MESSAGE_LOG_KEY="nettyMessageLog_key:";
    public static final String NETTY_CONSUMED_KEY="nettyConsumed_Key:";
    /**设置默认消息重试次数为0*/
    public static final Integer MESSAGE_RETRY_COUNT=0;
    /**设置消息重试次数最大为3*/
    public static final Integer MESSAGE_MAX_RETRY_COUNT=3;
    /**消息状态码已投递*/
    public static final Integer MESSAGE_DELIVERED=0;
    /**消息状态码投递成功*/
    public static final Integer MESSAGE_SUCCESS_TO_EXCHANGE=1;
    /**消息状态码投递失败->包括生产者到达交换机的失败和交换机发送消息到队列的失败*/
    public static final Integer MESSAGE_FAIL_TO_EXCHANGE_OR_QUEUE=2;
    /**消息状态码 已消费*/
    public static final Integer MESSAGE_CONSUMERED=3;
    /**消息状态码 消费失败*/
    public static final Integer MESSAGE_CONSUMERED_FAIL=4;


}
